5cf89b55ad0ad1afc01f5556805d7de748cd8635,hazelcast/src/main/java/com/hazelcast/impl/map/MapService.java,MapService,commit,#String#number#,67
Before Change
System.out.println(nodeService.getThisAddress() + " MapService commit " + txnId);
getPartitionContainer(partitionId).commit(txnId);
int maxBackupCount = 1; //txnLog.getMaxBackupCount();
takeBackups(new MapTxnBackupCommitOperation(txnId), partitionId, maxBackupCount);
}
public void rollback(String txnId, int partitionId) {
After Change
getPartitionContainer(partitionId).commit(txnId);
int maxBackupCount = 1; //txnLog.getMaxBackupCount();
try {
nodeService.takeBackups(new MapTxnBackupCommitOperation(txnId), partitionId, maxBackupCount, 60);
} catch (Exception e) {
throw new TransactionException(e);
}